c9803b6ad400b6daaf1ea54c6aa1bb1dfd1d3808,modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/PojoCacheStoreSelfTest.java,PojoCacheStoreSelfTest,doTestAllOps,#IgniteTx#boolean#,325
Before Change
store.removeAll(tx, Arrays.asList(k2, k3));
if (tx != null && commit) {
store.txEnd(tx, true);
tx = new DummyTx();
}
After Change
*/
private void doTestAllOps(@Nullable IgniteTx tx, boolean commit) {
try {
ses.newSession(tx);
final OrganizationKey k1 = new OrganizationKey(1);
final Organization v1 = new Organization(1, "Name1", "City1");
store.write(new CacheEntryImpl<>(k1, v1));
if (tx != null && commit) {
store.txEnd(true);
tx = new DummyTx();
ses.newSession(tx);
}
if (tx == null || commit)
assertEquals(v1, store.load(k1));
Collection<Cache.Entry<?, ?>> col = new ArrayList<>();
final OrganizationKey k2 = new OrganizationKey(2);
final Organization v2 = new Organization(2, "Name2", "City2");
final OrganizationKey k3 = new OrganizationKey(3);
final Organization v3 = new Organization(3, "Name3", "City3");
col.add(new CacheEntryImpl<>(k2, v2));
col.add(new CacheEntryImpl<>(k3, v3));
store.writeAll(col);
if (tx != null && commit) {
store.txEnd(true);
tx = new DummyTx();
ses.newSession(tx);
}
final AtomicInteger cntr = new AtomicInteger();
final OrganizationKey no_such_key = new OrganizationKey(4);
if (tx == null || commit) {
Map<Object, Object> loaded = store.loadAll(Arrays.asList(k1, k2, k3, no_such_key));
for (Map.Entry<Object, Object> e : loaded.entrySet()) {
Object key = e.getKey();
Object val = e.getValue();
if (k1.equals(key))
assertEquals(v1, val);
if (k2.equals(key))
assertEquals(v2, val);
if (k3.equals(key))
assertEquals(v3, val);
if (no_such_key.equals(key))
fail();
cntr.incrementAndGet();
}
assertEquals(3, cntr.get());
}
store.deleteAll(Arrays.asList(k2, k3));
if (tx != null && commit) {
store.txEnd(true);
tx = new DummyTx();
ses.newSession(tx);
}
if (tx == null || commit) {
assertNull(store.load(k2));
assertNull(store.load(k3));
assertEquals(v1, store.load(k1));
}
store.delete(k1);
if (tx != null && commit) {
store.txEnd(true);
tx = new DummyTx();